package com.leo.jdkcore.kafka;

import org.apache.kafka.clients.consumer.ConsumerRecord;

public interface KafkaMsgHandler<K,V> {
	
	boolean canPoll();
	
	void handlerMsg(V message,ConsumerRecord<K,V> record);
}
